package avicit.bdp.dcs.plugin.iotdb.param;

import avicit.bdp.dcs.plugin.BaseDataxParam;

import java.util.List;
import java.util.Map;

/**
 * @金航数码科技有限责任公司
 * @作者：liyb
 * @邮箱：liyb@avic-digital.com
 * @创建时间： 2021-01-27 18:09
 * @类说明：用于传参，构建json
 * @修改记录：
 */
public class IotdbDataxParam extends BaseDataxParam {

    // 列名
    private List<Map<String, Object>> columns;

    private String bootstrapServers;
    private String username;
    private String password;
    private String deviceId;
    private String paras;
    private List<String> preSql;
    private Integer batchSize;

    private List<Map<String, Object>> kafka2IotMap;
    private List<IotdbParam> writerColumns;
    // 源类型，hdfs、kafka
    private String sourceType;

    public static class IotdbParam {

        private String timeseries;
        private String deviceId;
        // 列名
        private List<Map<String, Object>> column;

        public String getTimeseries() {
            return timeseries;
        }

        public void setTimeseries(String timeseries) {
            this.timeseries = timeseries;
        }

        public String getDeviceId() {
            return deviceId;
        }

        public void setDeviceId(String deviceId) {
            this.deviceId = deviceId;
        }

        public List<Map<String, Object>> getColumn() {
            return column;
        }

        public void setColumn(List<Map<String, Object>> column) {
            this.column = column;
        }

    }

    public List<Map<String, Object>> getColumns() {
        return columns;
    }

    public void setColumns(List<Map<String, Object>> columns) {
        this.columns = columns;
    }

    public String getBootstrapServers() {
        return bootstrapServers;
    }

    public void setBootstrapServers(String bootstrapServers) {
        this.bootstrapServers = bootstrapServers;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getDeviceId() {
        return deviceId;
    }

    public void setDeviceId(String deviceId) {
        this.deviceId = deviceId;
    }

    public String getParas() {
        return paras;
    }

    public void setParas(String paras) {
        this.paras = paras;
    }

    public List<String> getPreSql() {
        return preSql;
    }

    public void setPreSql(List<String> preSql) {
        this.preSql = preSql;
    }

    public Integer getBatchSize() {
        return batchSize;
    }

    public void setBatchSize(Integer batchSize) {
        this.batchSize = batchSize;
    }

    public List<Map<String, Object>> getKafka2IotMap() {
        return kafka2IotMap;
    }

    public void setKafka2IotMap(List<Map<String, Object>> kafka2IotMap) {
        this.kafka2IotMap = kafka2IotMap;
    }

    public List<IotdbParam> getWriterColumns() {
        return writerColumns;
    }

    public void setWriterColumns(List<IotdbParam> writerColumns) {
        this.writerColumns = writerColumns;
    }

    public String getSourceType() {
        return sourceType;
    }

    public void setSourceType(String sourceType) {
        this.sourceType = sourceType;
    }

}
